952de60aec6abb295d5285c3e4474a04014b1038,qpid-jms-client/src/test/java/org/apache/qpid/jms/JmsSessionTest.java,JmsSessionTest,testCreateSharedConsumer,#,338

Before Change


    public void testCreateSharedConsumer() throws Exception {
        JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        try {
            session.createSharedConsumer(session.createTopic("test"), "subscription");
            fail("Should fail until implemented.");
        } catch (JMSException ex) {}
    }

After Change


    public void testCreateSharedConsumer() throws Exception {
        JmsSession session = (JmsSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        Topic topic = session.createTopic("test");
        JmsMessageConsumer consumer = (JmsMessageConsumer) session.createSharedConsumer(topic, "subscription");

        assertNotNull(consumer);
        assertNull("unexpected selector", consumer.getMessageSelector());